package com.dly.blog.service;

import com.dly.blog.domain.dto.MessageContentDto;
import com.dly.blog.domain.enums.ChatType;
import reactor.core.publisher.Flux;

import java.util.List;

public interface ChatProxy {

    /**
     * 类型匹配
     */
    boolean matching(ChatType chatType);

    /**
     * 信息发送
     */
    Flux<String> send(List<MessageContentDto> messages);
}
